package com.fastmms.analysis;

import java.util.List;

public interface AnalysisMessage {
    // 准备开始
    void ready(List<AnalysisBlock> analysisBlockList, Object param);

    // 执行
    void apply(long blockNo, long msgNo,long msgLingNo, byte[] keyData, byte[] valueData, Object param);

    // 完成
    void finish(long readCount, Object param);

    // 错误处理
    void error(AnalysisBlock errorBlock, long errorPoint, Object param, Exception e);
}
